package com.dove.task;

import com.alibaba.fastjson.JSON;
import com.alibaba.fastjson.JSONObject;

import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.stereotype.Component;

@Component
public class DefAsyncMQTask {

	private Logger logger = LoggerFactory.getLogger(this.getClass());

	public void onMessage(String body) {

		JSONObject jsonObj = JSONObject.parseObject(body);
		logger.info(JSON.toJSONString(jsonObj));

	}
}